var websocket = require('ws');
var mysql = require('mysql');
var pb = require('./proto');
/**数据库实例 */
// var sql = mysql.createConnection({
//     host: 'localhost',
//     user: 'root',
//     password: '201314',
//     database: 'card2048'
// });

// sql.connect((err, res) => {
//     if (err) {
//         console.error(err.message || err);
//     } else {
//         console.error("连接数据库成功！");
//     }
// });

/**websocket实例 */
var wss = new websocket.Server({ port: 8080 });
wss.on("connection", (ws, req) => {
    console.log("客户端连接！");
    ws.onmessage = (req) => {
        //console.error("请求参数：", req);
        //读取信息
        var data = req.data;
        var info = pb.Player.decode(data);
        console.log("信息解析", info);
        //test 给玩家+1金钱
        info.money++;
        //把接受的信息转发回去
        var data = pb.Player.encode(info).finish();
        ws.send(data);
    }
});



